package com.sangsang.domain.annotation;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * 作用： 插入式注解，自动实现cdc的consumer mapper等逻辑
 * 使用方法：标注在实体类上
 *
 * @author liutangqi
 * @date 2024/3/11 16:24
 */
@Retention(RetentionPolicy.SOURCE) //只在编译期有效，最终不会打进class文件中
@Target({ElementType.TYPE})
public @interface CDC {
    /**
     * 数据同步的topic
     */
    String topic();

    /**
     * 对应的kafka的组，默认是项目名
     */
    String groupId() default "${spring.application.name}";
}
